package com.gitee.xhs.operatorState.unionListState;

import org.apache.flink.api.common.state.ListStateDescriptor;
import org.apache.flink.api.common.typeinfo.TypeInformation;

import static com.gitee.xhs.StateConstant.FLINK_CHECK_POINT_PATH;

/**
 * @author BigHead
 * @date 2022/7/1 14:25
 * @description OperatorListStateConstant
 */
public class OperatorUnionListStateConstant {

    public static final String CUSTOM_OPERATOR_UNION_LIST_STATE_DIR = "operatorUnionListState/";

    public static final String OPERATOR_UNION_LIST_STATE_PATH = FLINK_CHECK_POINT_PATH + CUSTOM_OPERATOR_UNION_LIST_STATE_DIR;
    public static final String OPERATOR_UNION_LIST_STATE_UID = "operator-union-list-state-uid";
    public static final String OPERATOR_UNION_LIST_STATE_NAME = "operator-union-list-state";
    public static final ListStateDescriptor<Long> OPERATOR_UNION_LIST_STATE_DESCRIPTOR = new ListStateDescriptor<>(
            OPERATOR_UNION_LIST_STATE_NAME,
            TypeInformation.of(Long.class)
    );

}
